package cn.getech.data.development.bean.dag

import cn.getech.data.development.enums.DAGType
import cn.getech.data.development.enums.DAGType.DAGType

/**
 * flink dag node type
 */
class FlinkStreamTypeObj {
  var oper_type: DAGType = DAGType.select
  var tableName: String = null
  var outputTableName: String = null
  var insertName: String = null
  var sinkTableName: String = null
  var fields: Array[FlinkStreamFieldObj] = null

  // filter
  var fieldText: String = null

  // group by
  var groupName: String = null
  var windowType: String = null
  var windowName: String = null
  var interval: Long = 0L
  var unit: String = null
  var isWindow: Boolean = false

  // partition by
  var partition: String = null
  var order: String = null
  var alias_partition: String = null
}